package com.message.receive;

/**
 * Created by Administrator on 2018/3/29 0029.
 */
//@EnableBinding(ServiceMessageChannel.class)
public class Receiver {
  /*  private final static Logger logger = LoggerFactory.getLogger(Receiver.class);
    @Autowired
    private SocketServce socketServce;

    // 监听 binding 为 OrderIntf.INPUT_ORDER 的消息
    @StreamListener(ServiceMessageChannel.INPUT_MESSAGE)
    public void inputMessage(MessageStructure messageStructure) {
        String message=JSON.toJSONString(messageStructure);
        logger.info("收到消息了\n{}\n时间:{}",message,System.currentTimeMillis()/1000);
        socketServce.sendGroupMessage(message);
    }*/

}
